/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package CapaLogica;

import CapaAccesoBD.Conector;
import java.util.ArrayList;

/**
 *
 * @author Amejia
 */
public class MultiCongregacion {
    
    public  Congregacion crear(String id, String denominacion, int numMiembros, String codPostal,
            String direccion, String encargado) 
		throws Exception{
            
		Congregacion objCongregacion=null;
		String sql;
		sql = "INSERT INTO TCongregacion "+
		"VALUES ('"+id+"', '"+denominacion+"', "+numMiembros+", '"+codPostal+"', '"+direccion+"', '"+encargado+"');";
		try {
			Conector.getConector().ejecutarSQL(sql);
			objCongregacion = new Congregacion(id,denominacion,numMiembros,codPostal,direccion,encargado);
		}
		catch (Exception e) {
			throw new Exception (e.getMessage());
		}
		return objCongregacion;
	}
 
        public ArrayList<Congregacion> buscarCongregacionesPorDistrito(String pdistrito) throws Exception{
            Congregacion objCongregacion;
            ArrayList<Congregacion> listaCongregaciones;
            String sql;
            java.sql.ResultSet rs;
				sql = "SELECT * FROM TCongregaciones"+
                  " WHERE id_distrito ='"+pdistrito+"';";
            try{
                rs = Conector.getConector().ejecutarSQL(sql,true);
                listaCongregaciones = new ArrayList();
                if (rs.next()) {
                    do{
                        objCongregacion = new Congregacion(rs.getString("Id"), rs.getString("denominacion"), rs.getInt("num_Miembros"), rs.getString("codPostal"), rs.getString("direcion"),
                                rs.getString("encargado"));
                        listaCongregaciones.add(objCongregacion);
                    }while (rs.next());
                }
            }catch (Exception e){
                throw new Exception (e.getMessage());
            }
            rs.close();
            
            return listaCongregaciones;
        }
        

        public Congregacion buscarPorCodigo(String pcodigo) throws Exception{
            Congregacion objCongregacion=null;
            String sql;
            java.sql.ResultSet rs;
            sql = "SELECT * " + 
                  " FROM TCongregacion " + 
                  "WHERE Id = '"+pcodigo+"';";
            try{
                rs = Conector.getConector().ejecutarSQL(sql,true);
                if(rs.next())
                        objCongregacion = new Congregacion(rs.getString("Id"), rs.getString("denominacion"), rs.getInt("num_Miembros"), rs.getString("codPostal"), rs.getString("direcion"),
                                rs.getString("encargado"));
            }catch (Exception e){ 
                throw new Exception (e.getMessage());
            }
            rs.close();
            
            return objCongregacion;
        }
}
